package com.zhihui.kafka;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by hengxing on 2017/9/13.
 */
public interface MsgChannel {

    String  sampleSink="sampleSink";
    String  sampleSource="sampleSource";

    @Input
    SubscribableChannel sampleSink();


    @Output
    MessageChannel   sampleSource();

}
